package operator.create;

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;
import util.Printer;

class EmptyOperator {

    public static void main(String[] args) {
        empty();
    }

    static void empty(){
        Observable.empty().subscribeOn(Schedulers.io()).subscribe(new Observer<Object>() {
            @Override
            public void onSubscribe(Disposable d) {
                Printer.print("empty onSubscribe");
            }

            @Override
            public void onNext(Object object) {
                Printer.print("empty onNext");
            }

            @Override
            public void onError(Throwable e) {
                Printer.print("empty onError");
            }

            @Override
            public void onComplete() {
                Printer.print("empty onComplete");
            }
        });
    }

}
